package com.ming.rabbitmq.four;

import com.ming.rabbitmq.util.RabbitMqUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.MessageProperties;

import java.util.Scanner;

public class Producer1 {
    public static String name = "ack";
    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMqUtils.getChannel();
//        开启发布确认 用于确认信息
        channel.confirmSelect();
//    获取队列
//                     队列名 是否持久化 是否和其他消费者共享 是否自动删除 其他参数
        channel.queueDeclare(name, true, false, false, null);
        Scanner scanner = new Scanner(System.in);
        while (scanner.hasNext()) {
            String message = scanner.next();
//    发布信息
//                                 交换机 （路由key值）队列名  其他参数       消息体
//                                                        ↓消息持久化
            channel.basicPublish("", name, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
            System.out.println("消息发送完毕");
        }
    }
}
